package com.jirong.shop.controller;


import com.jirong.shop.pojo.TUser;
import com.jirong.shop.rabbitMQ.MQSender;
import com.jirong.shop.vo.RespBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

/**
 * <p>
 * 前端控制器
 * </p>
 *
 * @author jirong
 * @since 2022-01-13
 */
@Controller
@RequestMapping("/user")
public class TUserController {
    @Autowired
    private MQSender mqSender;

    //    /测试用户
    @RequestMapping("/info")
    @ResponseBody
    public RespBean info(TUser user) {
        return RespBean.success(user);
    }

    /*
    Fanout模式
     */
//    @RequestMapping("/mq")
//    @ResponseBody
//    public void mq() {
//        mqSender.send("Hello,world");
//    }

    /*
    Direct模式
     */
//    @RequestMapping("/mq/direct01")
//    @ResponseBody
//    public void mq01() {
//        mqSender.send01("Hello,Red");
//    }
//
//    @RequestMapping("/mq/direct02")
//    @ResponseBody
//    public void mq02() {
//        mqSender.send02("Hello,Green");
//    }
//     /*
//    Topic模式,建立了错误的交换机，要手动清除它，然后创建
//     */
//
//    /**
//     * 测试发送RabbitMQ消息
//     */
//    @RequestMapping("/mq/topic01")
//    @ResponseBody
//    public void mq03() {
//        mqSender.send03("Hello,Red");
//    }
//
//    /**
//     * 测试发送RabbitMQ消息
//     */
//    @RequestMapping("/mq/topic02")
//    @ResponseBody
//    public void mq04() {
//        mqSender.send04("Hello,Green");
//    }
//
//    /*
//    Headers
//     */
//    @RequestMapping("/mq/header01")
//    @ResponseBody
//    public void mq05() {
//        mqSender.send05("Hello,header01");
//    }
//
//    /**
//     * 测试发送RabbitMQ消息
//     */
//    @RequestMapping("/mq/header02")
//    @ResponseBody
//    public void mq06() {
//        mqSender.send06("Hello,header02");
//    }

}

